#include "../../client/rpc_client.hpp"

int main()
{
    //1.实例化客户端对象
    auto client=std::make_shared<myrpc::client::TopicClient>("127.0.0.1",7070);
    //2.创建主题
    bool ret=client->create("hello");
    if(ret==false)
    {
        ELOG("创建主题失败！");
    }
    //3.发布消息
    for(int i=0;i<10;i++)
    {
        client->publish("hello","hello world-"+std::to_string(i));
    }
    client->shutdown();

    return 0;
}